'use strict';
module.exports = {
	/**
	 * XXXnameXXX
	 * @url admin/datas/kh/today_data 前端调用的url参数地址
	 * data 请求参数
	 * @param {String} params1  参数1
	 */
	main: async (event) => {
		const db = uniCloud.database();
		let {
			data = {}, userInfo, util, filterResponse, originalParam
		} = event;
		let {
			customUtil,
			uniID,
			config,
			pubFun,
			vk,
			_
		} = util;
		let {
			uid,
			jrxh,
			todayStart
		} = data;
		let res = {
			code: 0,
			msg: ""
		};
		// 业务逻辑开始-----------------------------------------------------------
		res.jrxh = jrxh;
		//查询今日新增用户数
		res.num = await vk.baseDao.count({
			dbName: "uni-id-users",
			whereJson: {
				//必须是今天新增的
				register_date: _.gte(todayStart),
				//邀请码是当前代理商
				invite_code:userInfo._id
			}
		});

		//查询今日充值总金额
		res.jrczje = await vk.baseDao.sum({
			dbName: "a_recharge", // 表名
			fieldName: "shifu_amount", // 需要求和的字段名
			whereJson: {
				//支付状态必须是已支付，时间是今天
				pay_status: 1,
				_add_time: _.gte(todayStart),
				//邀请码是当前代理商
				invite_code:userInfo._id
			}
		});

		//查询今日充值笔数
		res.jrczbs = await vk.baseDao.count({
			dbName: "a_recharge", // 表名
			whereJson: { // 条件
				pay_status: 1,
				_add_time: _.gte(todayStart),
				invite_code:userInfo._id
			}
		});

		//新用户付费up值
		res.xyhffupz = await vk.baseDao.max({
			dbName: "a_recharge", // 表名
			fieldName: "shifu_amount", // 需要取最大值的字段名
			whereJson: { // 条件
				pay_status: 1,
				user_register_date: _.gte(todayStart),
				invite_code:userInfo._id,
				_add_time: _.gte(todayStart)
			}
		});

		//查询今日新用户充值总金额
		res.xyhczje = await vk.baseDao.sum({
			dbName: "a_recharge", // 表名
			fieldName: "shifu_amount", // 需要求和的字段名
			whereJson: { // 条件
				pay_status: 1,
				user_register_date: _.gte(todayStart),
				invite_code:userInfo._id,
				_add_time: _.gte(todayStart)
			}
		});

		//查询充值订单里，一共有多少个新付费用户
		res.xffyh = await vk.baseDao.selects({
			dbName: "a_recharge",
			// 主表where条件（分组前的筛选）
			pageSize: -1,//不限数量
			whereJson: {
				pay_status: 1,
				user_register_date: _.gte(todayStart),
				invite_code:userInfo._id,
				_add_time: _.gte(todayStart)
			},
			groupJson: {
				_id: "$user_id", // _id是分组id（_id:为固定写法，必填属性） $ 后面接字段名，如user_id字段进行分组
			}
		});

		//查询充值订单里，一共有多少个新付费用户
		res.jrczrs = await vk.baseDao.selects({
			dbName: "a_recharge",
			// 主表where条件（分组前的筛选）
			pageSize: -1,//不限数量
			whereJson: {
				pay_status: 1,
				_add_time: _.gte(todayStart),
				invite_code:userInfo._id
			},
			groupJson: {
				_id: "$user_id", // _id是分组id（_id:为固定写法，必填属性） $ 后面接字段名，如user_id字段进行分组
			}
		});
		
		// /**
		//  * 以下是获取昨日数据
		//  */
		
		// //昨日开始时间 = 今日开始时间减86400000（24小时）
		// var last_StartTime = todayStart - 86400000
		// //昨日结束时间
		// var last_EndTime = todayStart - 1
		
		// //查询昨日新增用户数
		// res.last_num = await vk.baseDao.count({
		// 	dbName: "uni-id-users",
		// 	whereJson: {
		// 		//邀请码是当前代理商
		// 		invite_code:userInfo._id,
		// 		register_date: _.and(_.gt(last_StartTime), _.lt(last_EndTime))
		// 	}
		// });
		
		// //查询昨日充值总金额
		// res.last_jrczje = await vk.baseDao.sum({
		// 	dbName: "a_recharge",
		// 	fieldName: "shifu_amount", // 需要求和的字段名
		// 	whereJson: {
		// 		//邀请码是当前代理商
		// 		invite_code:userInfo._id,
		// 		pay_status: 1,
		// 		_add_time: _.and(_.gt(last_StartTime), _.lt(last_EndTime))
		// 	}
		// });
		
		// //查询昨日充值笔数
		// res.last_jrczbs = await vk.baseDao.count({
		// 	dbName: "a_recharge",
		// 	whereJson: {
		// 		//邀请码是当前代理商
		// 		invite_code:userInfo._id,
		// 		pay_status: 1,
		// 		_add_time: _.and(_.gt(last_StartTime), _.lt(last_EndTime))
		// 	}
		// });
		
		// //昨日新用户付费up值
		// res.last_xyhffupz = await vk.baseDao.max({
		// 	dbName: "a_recharge",
		// 	fieldName: "shifu_amount", // 需要取最大值的字段名
		// 	whereJson: {
		// 		//邀请码是当前代理商
		// 		invite_code:userInfo._id,
		// 		pay_status: 1,
		// 		user_register_date: _.and(_.gt(last_StartTime), _.lt(last_EndTime))
		// 	}
		// });
		
		// //查询昨日新用户充值总金额
		// res.last_xyhczje = await vk.baseDao.sum({
		// 	dbName: "a_recharge",
		// 	fieldName: "shifu_amount", // 需要求和的字段名
		// 	whereJson: {
		// 		//邀请码是当前代理商
		// 		invite_code:userInfo._id,
		// 		pay_status: 1,
		// 		user_register_date: _.and(_.gt(last_StartTime), _.lt(last_EndTime)),
		// 	}
		// });
		
		// //查询昨日充值订单里，一共有多少个新付费用户
		// res.last_xffyh = await vk.baseDao.selects({
		// 	dbName: "a_recharge",
		// 	// 主表where条件（分组前的筛选）
		// 	pageSize: -1,//不限数量
		// 	whereJson: {
		// 		//邀请码是当前代理商
		// 		invite_code:userInfo._id,
		// 		pay_status: 1,
		// 		user_register_date: _.and(_.gt(last_StartTime), _.lt(last_EndTime)),
		// 	},
		// 	groupJson: {
		// 		_id: "$user_id", // _id是分组id（_id:为固定写法，必填属性） $ 后面接字段名，如user_id字段进行分组
		// 	}
		// });
		
		// //查询昨日充值订单里，一共有多少个新付费用户
		// res.last_jrczrs = await vk.baseDao.selects({
		// 	dbName: "a_recharge",
		// 	// 主表where条件（分组前的筛选）
		// 	pageSize: -1,//不限数量
		// 	whereJson: {
		// 		//邀请码是当前代理商
		// 		invite_code:userInfo._id,
		// 		pay_status: 1,
		// 		_add_time: _.and(_.gt(last_StartTime), _.lt(last_EndTime))
		// 	},
		// 	groupJson: {
		// 		_id: "$user_id", // _id是分组id（_id:为固定写法，必填属性） $ 后面接字段名，如user_id字段进行分组
		// 	}
		// });
		



		// 业务逻辑结束-----------------------------------------------------------
		return res;
	}
}
